package com.navinfo.tripanalysis.service.impl;

import com.navinfo.tripanalysis.common.arithmetic.common.OuterStatisticData;
import com.navinfo.tripanalysis.common.arithmetic.convert.StatisticDataParquetConvert;
import com.navinfo.tripanalysis.service.LoadTripDataService;
import org.apache.spark.sql.Row;

/**
 * 从hive表加载行程
 * @author 沈东生
 */
public class LoadTripServiceHiveImpl extends AbstractLoadDataHive<OuterStatisticData> implements LoadTripDataService {

    @Override
    protected OuterStatisticData fromRow(Row row) {
        return StatisticDataParquetConvert.fromRow(row);
    }
}
